package org.luxor.common.netty.protocol.handler.send;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;
import org.luxor.common.netty.protocol.message.NettyPubAckMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 消息确认
 *
 * @author Mr.yan @date 2023/12/8
 */
public class SendAckMessageHandler extends SimpleChannelInboundHandler<NettyPubAckMessage> {
    private static final Logger log = LoggerFactory.getLogger(SendAckMessageHandler.class);

    @Override
    public void channelRead0(ChannelHandlerContext ctx, NettyPubAckMessage nettySendAckMessage) throws Exception {
        // 保存发布应答
    }
}
